package com.zsy.filink.basic;

import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.util.Collector;

/**
 * @Author: Zhou ShiYang
 * @Description:
 * @Date:Create：in 2021/7/29 0:02
 **/
public class PKFlatMapFunction implements FlatMapFunction<String, String> {
    @Override
    public void flatMap(String value, Collector<String> out) throws Exception {
        String[] words = value.split(",");
        for (String word : words) {
            out.collect(word.toLowerCase().trim());
        }
    }
}
